746f320a3ae5cdb8fcec8db095ced7a5ffed3127,rxnetty-examples/src/main/java/io/reactivex/netty/examples/tcp/proxy/ProxyClient.java,ProxyClient,main,#String[]#,34

Before Change


        SocketAddress serverAddress = getServerAddress(ProxyServer.class, args);

        /*Create a new client for the server address*/
        TcpClient.<ByteBuf, ByteBuf>newClient(serverAddress)
                /*Create a new connection request, each subscription creates a new connection*/
                .createConnectionRequest()
                /*Upon successful connection, write "Hello World" and listen to input*/
                .flatMap(connection ->

After Change


        SocketAddress serverAddress = getServerAddress(ProxyServer.class, args);

        /*Create a new client for the server address*/
        TcpClient.<ByteBuf, ByteBuf>newClient(serverAddress)
                .enableWireLogging(LogLevel.DEBUG)
                /*Create a new connection request, each subscription creates a new connection*/
                .createConnectionRequest()
                /*Upon successful connection, write "Hello World" and listen to input*/
                .flatMap(connection ->